﻿using System;
using System.Buffers;

namespace eNets.CBK.Pipe;

partial class MultiplePipe<T>
{
    sealed class MultiplePipeReader : IPipeReader<T>
    {
        public long ReadableLength { get; }

        public void AddListener(Action listener)
        {
            throw new NotImplementedException();
        }

        public void RcvAsync()
        {
            throw new NotImplementedException();
        }

        public void Flush()
        {
            throw new NotImplementedException();
        }

        public ReadOnlySequence<T> GetReadableSequence()
        {
            throw new NotImplementedException();
        }

        public void ReaderAdvanceTo(SequencePosition consumed)
        {
            throw new NotImplementedException();
        }

        public void ReaderAdvanceTo(SequencePosition consumed, SequencePosition examined)
        {
            throw new NotImplementedException();
        }
    }
}